category: sub_main
step: 2_staging
sub_step: 1_join
in_main_macro: join
doc_status: readymacro join_appsflyer_events
| Name | Category | In Sub-Main Macro | Doc Status |
|---|---|---|---|
| get_relations_by_re | auxiliary | join_appmetrica_events, join_appmetrica_registry_appprofilematching, join_appsflyer_events, join_mt_datestat, join_sheets_periodstat, join_vkads_datestat, join_utmcraft_registry_utmhashregistry, join_yd_datestat, join_yd_datestat_smart, join_ym_events | ready |
Этот подвид макроса join предназначен для работы с данными источника appsflyer (они относятся к пайплайну events).
Этот макрос принимает следующие аргументы:
sourcetype_name,
pipeline_name,
relations_dict,
date_from,
date_to,
params,
limit0=none
Макрос обрабатывает данные стрима in_app_events из источника appsflyer. Эти данные относятся к пайплайну events.
Для вышеуказанного стрима макрос ищет relations при помощи вспомогательного макроса get_relations_by_re, затем создаёт таблицу-источник при помощи вспомогательного макроса dbt_utils.union_relations. (Этот макрос из пакета dbt_utils, он не относится к datacraft).
Далее полученные данные макрос обрабатывает (происходит переименование полей, для некоторых столбцов вводится LowCardinality).
Для этой таблицы задаётся её линк (это будет использоваться на будущих шагах):
toLowCardinality('&&&') AS __linkЕсли аргумент limit0 активирован, то в конце SQL-запроса будет добавлено LIMIT 0.
Файл в формате sql в папке models. Название файла join_appsflyer_events
Содержимое файла:
-- depends_on: {{ ref('incremental_appsflyer_events_default_in_app_events') }}
{{ datacraft.join() }}